flume-sink報錯 java.lang.IllegalStateException: close() called when transaction is OPEN - you must eit

1. 確認代碼無誤（根據情況修改，表示若獲得不了數據不會自動commit或者rollback）： Event event = channel.take(); if (event == null ...